package com.pw.study.flink.transfrom

import org.apache.flink.configuration.Configuration
import org.apache.flink.streaming.api.functions.co.RichCoFlatMapFunction
import org.apache.flink.util.Collector

class MyRichCoFlatMap() extends RichCoFlatMapFunction[(String, Int), (String, String),String]{
  override def open(parameters: Configuration): Unit = {

  }
  override def flatMap1(word: (String, Int), collector: Collector[String]): Unit = {

  }

  override def flatMap2(w2: (String, String), collector: Collector[String]): Unit = {

  }
}
